package com.codejiwei.flink.cdc;

import org.apache.flink.api.common.serialization.SerializationSchema;
import org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchema;
import org.apache.kafka.clients.producer.ProducerRecord;

/**
 * author: codejiwei
 * date: 2023/8/27
 * desc:
 **/
public class CustomKafkaSerializationSchema implements KafkaRecordSerializationSchema<KafkaRecord> {
    @Override
    public void open(SerializationSchema.InitializationContext context, KafkaSinkContext sinkContext) throws Exception {

    }

    @Override
    public ProducerRecord<byte[], byte[]> serialize(KafkaRecord element, KafkaSinkContext context, Long timestamp) {
        return null;
    }
}
